
package cn.hz.camel;

import java.io.Serializable;
import java.sql.Timestamp;
import java.util.Date;
import java.util.List;
import java.util.concurrent.LinkedBlockingQueue;

 

public abstract class MzHandle  {
   protected MysqlClient inClient;

   protected MysqlClient outClient;
   public MzResult handle1(){
	   List<Object> list=handle();
	   
	   MzResult rs=MzTools.ls2rs(list,100);
	   
	   return rs;
   }
   public abstract List<Object> handle();
   
   
   	public void outHandle1(MzMessage msg){
   	    //System.out.println("ccc " +msg.getBody().getRess().size());
   		for( MzResObj mzobj:msg.getBody().getRess()){
   			
   			outHandle(mzobj);
   		    
   			msg.getInQu().add(mzobj);
   		}
   	}
   	
   public abstract boolean outHandle(MzResObj obj);
   
   
   public abstract boolean resHandle(MzResObj obj);

   public MysqlClient getInClient() {
	   return inClient;
   }

   public void setInClient(MysqlClient inClient) {
	   this.inClient = inClient;
   }

   public MysqlClient getOutClient() {
	   return outClient;
   }

   public void setOutClient(MysqlClient outClient) {
	   this.outClient = outClient;
   }
   
   
}
